package com.linb.pan.stream.core;

import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

@Component(value = "defaultStreamProducer")
public class DefaultStreamProducer extends AbstractStreamProducer {

    /**
     * 发送消息前的钩子函数
     */
    @Override
    protected void preSend(Message message) {
        //默认生产者什么都不做
    }

    /**
     * 发送消息后的钩子函数
     */
    @Override
    protected void afterSend(Message message, boolean result) {
        //默认生产者什么都不做
    }

}
